6e7487e58587ae592bd827535e605206d8f0fdd8,src/freenet/node/PeerMessageQueue.java,PeerMessageQueue,addMessages,#number#number#number#ArrayList#number#,996
Before Change
return;
}
if(logMINOR) Logger.minor(this, "Trying bulk");
s = queuesByPriority[DMT.PRIORITY_BULK_DATA].addPriorityMessages(Math.abs(size), minSize, maxSize, now, messages, addPeerLoadStatsRT, addPeerLoadStatsBulk, incomplete);
if(s != size) {
size = s;
}
if(incomplete.value || messages.size() >= 1) {
return;
After Change
return;
}
if(logMINOR) Logger.minor(this, "Trying bulk");
queuesByPriority[DMT.PRIORITY_BULK_DATA].addPriorityMessages(Math.abs(size), minSize, maxSize, now, messages, addPeerLoadStatsRT, addPeerLoadStatsBulk, incomplete);
if(incomplete.value || messages.size() >= 1) {
return;
}